package com.ibm.cps.servlet.starter.spark;

import com.ibm.cps.servlet.starter.CommandlineStarter;
import com.ibm.util.LocalConfig;

public class SparkLocalStarter extends CommandlineStarter {

	public SparkLocalStarter(String path) {
		super(path);
	}

	@Override
	public String createShellCommand(String tenantId) {
		return "sh " + shellPath + " " + tenantId + " " + LocalConfig.TASK_PER_SPARK_TOPOLOGY + " " + LocalConfig.SPARK_JAR_PATH;
	}

}
